//package com;
//
//import org.junit.Test;
//import org.junit.runner.RunWith;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.boot.test.context.SpringBootTest;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.test.context.junit4.SpringRunner;
//
//import com.system.constants.QueueConstant;
//
//import lombok.extern.slf4j.Slf4j;
//
//@Slf4j
//@RunWith(SpringRunner.class)
//@SpringBootTest(classes = TimeyStartup.class)
//public class KafkaDemo1 {
//
//	@Autowired
//	private KafkaTemplate<String, String> kafkaTemplate;
//	
//	/**
//	 * 增加
//	 */
//	@Test
//	public void setVal() {
//		for (int i = 0; i < 20; i++) {
//			kafkaTemplate.send(QueueConstant.PROC_TEST_TOPIC, "这个啊哈哈哈哈哈" + i).addCallback(success -> {
//				// 消息发送到的topic
//				String topic = success.getRecordMetadata().topic();
//				// 消息发送到的分区
//				int partition = success.getRecordMetadata().partition();
//				// 消息在分区内的offset
//				long offset = success.getRecordMetadata().offset();
//				log.info("发送消息成功topic:{}, partition:{}, offset:{}", topic, partition, offset);
//			}, failure -> {
//				log.info("发送消息失败:{}", failure.getMessage());
//			});
//			try {
//				Thread.sleep(1000);
//			} catch (InterruptedException e) {
//				e.printStackTrace();
//			}
//		}
//	}
//
//}
